#include "clientsubthread.h"
#include "taskqueue.h"
#include <QDebug>

ClientSubThread::ClientSubThread(QObject *parent) : QThread(parent)
{

}

// 客户端子线程的处理函数
void ClientSubThread::run()
{
    TaskQueue* taskQ = TaskQueue::getInstance();
    // 一直, 不停的读任务队列 (死循环)
    while(1)
    {
        // 从任务队列中取出一个任务
        Task t = taskQ->takeTask();
        // 处理这个任务(调用这个任务函数)
        t.function(t.arg);
        qDebug() << "当前任务处理完毕, 准备处理下一个...";
    }
}
